caced3749bdf640abf2a7f06056f6c29789385e4,cdap-watchdog/src/test/java/co/cask/cdap/metrics/store/cube/AbstractCubeTest.java,AbstractCubeTest,test,#,43
Before Change
writeInc(cube, "metric1", 7, 3, "1", "1", null);
writeInc(cube, "metric1", 8, 2, null, "1", null);
writeInc(cube, "metric1", 9, 1, null, null, null);
writeInc(cube, "metric1", 10, 2, "1", "1", "1", "1");
writeInc(cube, "metric1", 11, 3, "1", "1", "1", null);
writeInc(cube, "metric1", 12, 4, "2", "1", "1", "1");
writeInc(cube, "metric1", 13, 5, null, null, null, "1");
After Change
ImmutableList.of("tag1"));
int resolution = 1;
Cube cube = getCube("myCube", new int[] {resolution}, ImmutableList.of(agg1, agg2));
// write some data
// NOTE: we mostly use different ts, as we are interested in checking incs not at persist, but rather at query time
writeInc(cube, "metric1", 1, 1, "1", "1", "1");
writeInc(cube, "metric1", 1, 1, "1", "1", "1");
writeInc(cube, "metric1", 2, 2, null, "1", "1");
writeInc(cube, "metric1", 3, 3, "1", "2", "1");
writeInc(cube, "metric1", 3, 5, "1", "2", "3");
writeInc(cube, "metric1", 3, 7, "2", "1", "1");
writeInc(cube, "metric1", 4, 4, "1", null, "2");
writeInc(cube, "metric1", 5, 5, null, null, "1");
writeInc(cube, "metric1", 6, 6, "1", null, null);
writeInc(cube, "metric1", 7, 3, "1", "1", null);
writeInc(cube, "metric1", 8, 2, null, "1", null);
writeInc(cube, "metric1", 9, 1, null, null, null);
// writing in batch
cube.add(ImmutableList.of(
getFact("metric1", 10, 2, "1", "1", "1", "1"),
getFact("metric1", 11, 3, "1", "1", "1", null),
getFact("metric1", 12, 4, "2", "1", "1", "1"),
getFact("metric1", 13, 5, null, null, null, "1")